package com.lingjtx.ai.service;

import com.lingjtx.ai.po.AiChatQueryPo;
import com.lingjtx.ai.po.ChatMsgFeedbackPo;
import org.springframework.http.codec.ServerSentEvent;
import org.springframework.http.server.reactive.ServerHttpRequest;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

public interface ChatService {

    Flux<ServerSentEvent<String>> completions(AiChatQueryPo model, ServerHttpRequest request);

    Mono<String> stop(String task_id, ChatMsgFeedbackPo model);

    Mono<String> feedback(String message_id, ChatMsgFeedbackPo model);
}
